# 定义agent名称
a1.sources = k1
a1.sinks = k2
a1.channels = c1

# 配置Kafka源
a1.sources.k1.type = org.apache.flume.source.kafka.KafkaSource
a1.sources.k1.zookeepers = node101:2181
a1.sources.k1.kafka.bootstrap.servers = node101:9092
a1.sources.k1.kafka.topics = host_zzdetail2
a1.sources.k1.kafka.consumer.group.id = www_host_zzdetail2_group

# 配置MySQL sink
a1.sinks.k2.type = com.cloudera.flume.sink.DBSink
a1.sinks.k2.driverClass = com.mysql.jdbc.Driver
a1.sinks.k2.connectionString = jdbc:mysql://hllxd101:53149/db58_zp_bi_dev
a1.sinks.k2.user = zpbi_wr
a1.sinks.k2.password = 39086120578ddd85
a1.sinks.k2.sql = INSERT INTO tbl_host_zzdetail (content, content2) VALUES (content, 'abc123')
a1.sinks.k2.batchSize = 100

# 定义通道
a1.channels.c1.type = memory
a1.channels.c1.capacity = 1000
a1.channels.c1.transactionCapacity = 100

# 绑定源通道和目的地
a1.sources.k1.channels = c1
a1.sinks.k2.channel = c1

